package com.china.produce.config.kafka;

import lombok.Data;
import java.util.function.Consumer;

/**
 * @ClassName
 * @Author niujie
 * @Version
 * @Description
 * @CreateTime 2023/12/2
 */
@Data
public class KafkaSortConsumerConfig<E> {

    /**
     * 业务名称
     */
    String bizName;

    /**
     * 并发级别，多少的队列与线程处理任务
     */
    Integer concurrentSize;

    /**
     * 业务处理服务
     */
    Consumer<E> bizService;
}
